package com.hub.realtime.flinkshims.core;

import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableDescriptor;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.module.ModuleEntry;

public class TableContext extends FlinkTableBase{
    public TableContext(ParameterTool parameter, StreamExecutionEnvironment senv, TableEnvironment tableEnv) {
        super(parameter,senv, tableEnv);
    }


    @Override
    public void useModules(String... strings) {
        tableEnv.useModules(strings);
    }

    @Override
    public void createTemporaryTable(String s, TableDescriptor tableDescriptor) {
        tableEnv.createTemporaryTable(s,tableDescriptor);
    }

    @Override
    public void createTable(String s, TableDescriptor tableDescriptor) {
        tableEnv.createTable(s,tableDescriptor);
    }

    @Override
    public Table from(TableDescriptor tableDescriptor) {
        return tableEnv.from(tableDescriptor);
    }

    @Override
    public ModuleEntry[] listFullModules() {
        return tableEnv.listFullModules();
    }
}

